In ZioKafkaConsumerBenchmark.throughput:

Consumer
             .plainStream(Subscription.topics(topic1), Serde.byteArray, Serde.byteArray)
             .tap { _ =>
               counter.updateAndGet(_ + 1).flatMap(count => Consumer.stopConsumption.when(count == recordCount))
             }

Do you think it would be more fair to replace the tap with a tapChunk? In the manual kafka equivalent benchmark, we also process records by the batch instead of per record.

Do you think it would be more fair to replace the tap with a tapChunk?

Yes, I agree. Will you make a PR?

See #1409